//引入express模块
const express = require('express');
//引入连接池
const pool = require('../pool.js');
//创建路由器
const r = express.Router();
//http://127.0.0.1:8080/
r.post('/',(req,res,next)=>{
    //获取post请求的数据
    let obj = req.body;
    console.log(obj);
    //验证各项数据是否为空
    if(!obj.product_id){
        res.send({code:406,msg:'product_id不能为空'});
        return;
    }
    if(!obj.count){
        res.send({code:402,msg:'count不能为空'});
        return;
    }
    //执行sql语句命令，将获取的数据插入到数据表scp_shopping中
     pool.query('insert into scp_shopping set ?',[obj],(err,result)=>{
         if(err){
             next(err);
             return;
         };
         console.log(result);
         res.send({code:200,msg:'添加成功'});
    });
});


//导出数据库
module.exports = r;